package com.surfilter.massdata.spark.util.ipcheck;
import java.io.Serializable;

import com.surfilter.massdata.spark.bean.ipcheck.ErrIp;

import scala.collection.Iterator;
import scala.runtime.AbstractFunction1;
import scala.runtime.BoxedUnit;
/** 
* @author  hutao
* @date 创建时间：2017年5月22日 下午2:57:35 
* @Description：JavaRdd<ErrIP> foreachpartion实现
* @version 1.0 
* 
**/

public abstract class JavaForeachPartitionErrIpRDDFunc extends AbstractFunction1<Iterator<ErrIp>, BoxedUnit> implements Serializable {
	private static final long serialVersionUID = 1L;

	@Override
    public BoxedUnit apply(Iterator<ErrIp> it) {
        call(it);
        return BoxedUnit.UNIT;
    }
    
    public abstract void call(Iterator<ErrIp> it);
}
